package cn.itcast.consumer.processor;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MyProcessor {

	String INPUT_ORDER = "inputOrder";
	String OUTPUT_ORDER = "outputOrder";

	@Input("inputOrder")
	SubscribableChannel inputOrder();

	@Output("outputOrder")
	MessageChannel outputOrder();
}
